package com.hc.rabbit;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MQController {  //如果我们模拟发微博，那么这个控制器应该叫做WeiboController

    @Autowired
    AmqpTemplate amqpTemplate;

    @RequestMapping("/sendWeibo")
    public String sendWeibo(){

        String[] emails={"yangmi@qq.com","liuyifei@qq.com","yixiangqixi@qq.com"};

        for(String mail:emails){
            //为了避免发送邮件的程序拖垮当前发微博的功能，所以我们把发送邮件的任务踢出去了

            //所以我们需要告诉对方程序要给那些人发送邮件
            amqpTemplate.convertAndSend("mail_queue",mail+"|亲爱的小粉,我刚刚发了微博---这次听点不一样的---快乐围观吧");

        }

        return "send success";

    }

    public String sendWeibo2(){

        
    }



}
